# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms_point_hi.dm.dm_bg_customer_vip_statis_ht import dm_bg_customer_vip_statis_ht
jms_oracle__dm_bg_customer_vip_statis_ht = BashOperator(
    task_id='jms_oracle__dm_bg_customer_vip_statis_ht',
    execution_timeout=timedelta(hours=1),
    email=['yl_etl@yl-scm.com','wangmenglei@jtexpress.com'],
    # name='jms_oracle__dm_bg_customer_vip_statis_ht_{{ execution_date | date_add(1) | cst_ds }}',
    bash_command="jms_point_hi/doris/dm_bg_customer_vip_statis_ht/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

jms_oracle__dm_bg_customer_vip_statis_ht << [dm_bg_customer_vip_statis_ht]